BaseSubjectAsync class¶

Summary¶

View source

        Provides a base class for asynchronous subjects that support both publishing values to observers and receiving
        values asynchronously.
        

classDiagram
class BaseSubjectAsync~T~
class ObservableAsync~T~
ObservableAsync~T~ <|-- BaseSubjectAsync~T~
class ISubjectAsync~T~ {
    <>
}
ISubjectAsync~T~ <|.. BaseSubjectAsync~T~
class IObserverAsync~T~ {
    <>
}
IObserverAsync~T~ <|.. BaseSubjectAsync~T~
class IAsyncDisposable {
    <>
}
IAsyncDisposable <|.. BaseSubjectAsync~T~
class IObservableAsync~T~ {
    <>
}
IObservableAsync~T~ <|.. BaseSubjectAsync~T~

Inherits from: ObservableAsync

Implements: ISubjectAsync, IObserverAsync, IAsyncDisposable, IObservableAsync

Remarks¶

This class enables the implementation of asynchronous subjects that can broadcast values, errors, and completion notifications to multiple observers. It manages observer registration, notification, and completion in a thread-safe manner. Derived classes should override the core notification methods to customize how observers are notified asynchronously. The subject supports asynchronous subscription and notification patterns, making it suitable for reactive and event-driven programming scenarios.

Constructors¶

Methods¶